bd23bcdc5d03267e3e4edee739f5eced0986f3b8,rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/continuations/JMSContinuation.java,JMSContinuation,updateContinuations,#boolean#,154

Before Change


    
    protected void updateContinuations(boolean remove) {

        modifyList(remove);
        
        if (jmsConfig.getMaxSuspendedContinuations() < 0
            || jmsListener.getCacheLevel() >= DefaultMessageListenerContainer.CACHE_CONSUMER) {

After Change


        
        // throttle the flow if there're too many continuation instances in memory
        synchronized (continuations) {
            modifyList(remove);
            if (remove && !BOGUS_MESSAGE_SELECTOR.equals(currentMessageSelector)) {
                jmsListener.setMessageSelector(currentMessageSelector);
                currentMessageSelector = BOGUS_MESSAGE_SELECTOR;